package com.dingding.queue.queue.consumer;

import java.util.ArrayList;
import java.util.List;

import org.springframework.stereotype.Component;

@Component("consumerManager")
public class ConsumerManager extends AbstractManager {

	private List<AbstractConsumer> list = new ArrayList<AbstractConsumer>();

	@Override
	public void addConsumer(AbstractConsumer abstractConsumer) {

		list.add(abstractConsumer);

	}

	@Override
	public void notifyConsumer() {

		for (AbstractConsumer abstractConsumer : list) {
			abstractConsumer.intital();
		}

	}

	@Override
	public void intital() {

	}

}
